const db = require('./mysql');

exports.query = function (sql, arr = []) {
	return new Promise((resolve, reject) => {
		db.query(sql, [...arr], function (err, results) {
			// 1. 执行 SQL 语句失败
			if (err) {
				reject(err);
				return;
			}
			// 2. 执行 SQL 语句成功，但是查询到的数据条数少于0
			if (results.length < 0) {
				reject(0);
			}
			resolve(results);
		});
	});
};

exports.updata = function (sql, val = []) {
	return new Promise((resolve, reject) => {
		db.query(sql, [...val], (err, results) => {
			// 1. 执行 SQL 语句失败
			if (err) {
				reject(err);
				return;
			}
			// 2. 执行 SQL 语句成功，但是查询到的数据条数少于0
			if (results.affectedRows < 1) {
				reject("sql执行成功,但没效果");
			}

			// 3. 将信息响应给客户端
			resolve(1);
		});
	});
};

exports.insert = function (sql, obj = {}) {
	return new Promise((resolve, reject) => {
		db.query(sql, obj, function (err, results) {
			// 1. 执行 SQL 语句失败
			if (err) {
				reject(err);
				return;
			}
			// 2. 执行 SQL 语句成功，但是查询到的数据条数少于0
			if (results.length < 0) {
				reject(0);
			}
			resolve(results);
		});
	});
};